package com.roy.minimq.remoting.domain.nettyclient;

/**
 * @author ：楼兰
 * @date ：Created in 2021/8/9
 * @description:
 **/

public class NettyClientConfig {

    private int clientWorkThreads = 4;
    private int connectTimeoutMillis = 3000;
    private int clientSocketSndBufSize = 65535;
    private int clientSocketRcvBufSize = 65535;
    //oneway请求信号容量
    private int clientOnewaySemaphoreValue = 65535;
    //async请求信号容量
    private int clientAsyncSemaphoreValue = 65535;
    // 心跳超时时间
    private int clientChannelMaxIdleTimeSeconds = 120;

    public int getClientChannelMaxIdleTimeSeconds() {
        return clientChannelMaxIdleTimeSeconds;
    }

    public void setClientChannelMaxIdleTimeSeconds(int clientChannelMaxIdleTimeSeconds) {
        this.clientChannelMaxIdleTimeSeconds = clientChannelMaxIdleTimeSeconds;
    }

    public int getClientOnewaySemaphoreValue() {
        return clientOnewaySemaphoreValue;
    }

    public void setClientOnewaySemaphoreValue(int clientOnewaySemaphoreValue) {
        this.clientOnewaySemaphoreValue = clientOnewaySemaphoreValue;
    }

    public int getClientAsyncSemaphoreValue() {
        return clientAsyncSemaphoreValue;
    }

    public void setClientAsyncSemaphoreValue(int clientAsyncSemaphoreValue) {
        this.clientAsyncSemaphoreValue = clientAsyncSemaphoreValue;
    }

    public int getClientWorkThreads() {
        return clientWorkThreads;
    }

    public void setClientWorkThreads(int clientWorkThreads) {
        this.clientWorkThreads = clientWorkThreads;
    }

    public int getConnectTimeoutMillis() {
        return connectTimeoutMillis;
    }

    public void setConnectTimeoutMillis(int connectTimeoutMillis) {
        this.connectTimeoutMillis = connectTimeoutMillis;
    }

    public int getClientSocketSndBufSize() {
        return clientSocketSndBufSize;
    }

    public void setClientSocketSndBufSize(int clientSocketSndBufSize) {
        this.clientSocketSndBufSize = clientSocketSndBufSize;
    }

    public int getClientSocketRcvBufSize() {
        return clientSocketRcvBufSize;
    }

    public void setClientSocketRcvBufSize(int clientSocketRcvBufSize) {
        this.clientSocketRcvBufSize = clientSocketRcvBufSize;
    }
}

